package com.ht.callback.kafka;

import java.util.Map;

import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;

/**
 * kafka消息类
 * @author asq
 * @param <T>
 * @createTime 2024年12月6日 16:30:39
 */
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class KafkaMessage<T> {
	private String messageId; // 消息ID
	private T data; // 消息数据
	private String type; // 消息类型
	private Long timestamp; // 时间戳
	private Map<String, String> headers; // 消息头
}